-- SET sql-client.execution.result-mode=TABLEAU;
-- 执行命令： sql-client.sh -f flink_host_zzdetail.q

CREATE TABLE hdp_lbg_supin_ods_tsar_detail2 (
  content STRING
) WITH (
  'connector' = 'kafka',
  'topic' = 'host_zzdetail2',
  'properties.bootstrap.servers' = 'node101:9092',
  'format'='json'
);

CREATE TABLE hdp_lbg_supin_ods_tsar_detail (
  content STRING
) WITH (
  'connector' = 'kafka',
  'topic' = 'host_zzdetail',
  'properties.bootstrap.servers' = 'node101:9092',
  'format' = 'raw'
);

INSERT INTO hdp_lbg_supin_ods_tsar_detail2
SELECT
  content
FROM hdp_lbg_supin_ods_tsar_detail
